package com.example.streamdemo.channel;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @Package: com.example.streamdemo.channel
 * @ClassName: InputChannel
 * @Author: Think
 * @CreateTime: 2021/7/15 13:58
 * @Description:
 */
public interface MyInputChannel {

    @Input("myInput")
    SubscribableChannel myInput();

}
